package com.teradata.multithread.dsrptor;

import com.lmax.disruptor.EventHandler;

import java.util.concurrent.TimeUnit;

/**
 * @author: lyndon
 * @version: 1.0
 * @date: 2019/2/18
 */
public class SftpGetFileHandler implements EventHandler<MessageEvent> {
    @Override
    public void onEvent(MessageEvent messageEvent, long l, boolean b) throws Exception {

        String id = messageEvent.getMessage().getId();
        String name = messageEvent.getMessage().getName();

        Thread.sleep(1000);
        System.out.println(Thread.currentThread().getName() + "-Sftp" + "-" + l + "-" + b + "-id:" + id + "-name:" + name);

    }
}
